package com.markhsiu.store;

import io.openmessaging.demo.DefaultBytesMessage;

public interface StoreService {

	public void init();
	
	public void put(DefaultBytesMessage message);
	
	public DefaultBytesMessage poll(String topic);
	
	public void flush();
	
	public void destory();
	
}
